package cn.itcast.flink.base;

import java.util.concurrent.PriorityBlockingQueue;

/**
 * Author itcast
 * Date 2021/8/2 23:30
 * Desc TODO
 */
public class QueueDemo {
    public static void main(String[] args) {
        PriorityBlockingQueue<Integer> queue = new PriorityBlockingQueue<>(
                3
        );
        queue.add(15);
        queue.add(12);
        queue.add(17);
        for (Integer integer : queue) {
            System.out.println(integer);
        }
    }
}
